package cn.micro.flink.source;

import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

public class FileSourceTask {

    public static void main(String[] args) throws Exception {
        //获取执行环境
        StreamExecutionEnvironment executionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment();



        //执行
        executionEnvironment.execute("FILE-SOURCE-TASK");
    }
}
